引入依赖 javamail、jcommon、jfreechart
1.8.3 1.0.23 1.0.17 org.apache.geronimo.javamail geronimo-javamail_1.4_provider ${javamail-version} org.jfree jcommon ${jcommon.version} org.jfree jfreechart ${jfreechart.version}
创建邮件发送模板，delay-mail.vm
Title 滞留率分析报表
#foreach($element in $datas) 仓库 初始化 拣货中 拣货完成 装箱中 装箱完成 交接中 交接完成 已出库 合计 滞留率 及时率 #end #if($element.warehouseName) $element.warehouseName #end #if($element.countInit) $element.countInit #end #if($element.countPicking) $element.countPicking #end #if($element.countPickFinish) $element.countPickFinish #end #if($element.countPacking) $element.countPacking #end #if($element.countPackFinish) $element.countPackFinish #end #if($element.countTransferring) $element.countTransferring #end #if($element.countTransferFinish) $element.countTransferFinish #end #if($element.countDelivery) $element.countDelivery #end #if($element.countTotal) $element.countTotal #end #if($element.delayRate) $element.delayRate #end #if($element.timelyRate) $element.timelyRate #end 
系统邮件(请勿回复) | 药品技术中心—供应链
邮件工具类 MailUtil.java
package com.yyw.scs.util;import com.yyw.scs.model.Email;import org.apache.commons.lang.StringUtils;import org.apache.log4j.Logger;import org.apache.velocity.app.VelocityEngine;import org.omg.CORBA.OBJ_ADAPTER;import org.springframework.ui.velocity.VelocityEngineUtils;import javax.activation.DataHandler;import javax.activation.DataSource;import javax.mail.*;import javax.mail.internet.*;import javax.mail.util.ByteArrayDataSource;import java.io.*;import java.util.*;public class MailUtils { private static Logger log = Logger.getLogger(MailUtils.class); public static final String HTML_CONTENT = "text/html;charset=UTF-8"; public static final String ATTACHMENT_CONTENT = "text/plain;charset=gb2312"; private static VelocityEngine velocityEngine; public void sendEmail(T t, String title, String[] to, String[] bcc, String templateName) { Map map = new HashMap(); map.put("datas", t); Email email = new Email.Builder(title, to, null).model(map).templateName(templateName).bcc(bcc).build(); sendEmail(email); } public void sendEmail(T t, String imgPath, String title, String[] to, String[] bcc, String templateName) { Map map = new HashMap(); map.put("datas", t); map.put("imgPath", imgPath); Email email = new Email.Builder(title, to, null).model(map).templateName(templateName).bcc(bcc).build(); sendEmail(email); } public void sendEmail(String title, String[] to, String[] bcc, String templateName, Map data) { Email email = new Email.Builder(title, to, null).model(data).templateName(templateName).bcc(bcc).build(); sendEmail(email); } public void sendEmail(String title, String[] to, String[] bcc, String content, byte[] data, String fileName, String fileType) { Email email = new Email.Builder(title, to, content).bcc(bcc).data(data).fileName(fileName).fileType(fileType).build(); sendEmail(email); } public void sendEmail(String title, String[] to, String[] bcc, String templateName, byte[] data, String fileName, String fileType, Map map) { Email email = new Email.Builder(title, to, null).model(map).templateName(templateName).bcc(bcc).data(data).fileType(fileType).fileName(fileName).build(); sendEmail(email); } public void sendEmail(T t, String title, String[] to, String[] bcc, String templateName, byte[] data, String fileName, String fileType) { Map map = new HashMap(); map.put("datas", t); Email email = new Email.Builder(title, to, null).model(map).templateName(templateName).bcc(bcc).data(data).fileType(fileType).fileName(fileName).build(); sendEmail(email); } public void sendEmail(String title, String[] to, String content) { Email email = new Email.Builder(title, to, content).bcc(null).build(); sendEmail(email); } public void sendEmail(String title, String[] to, String[] bcc, String content) { Email email = new Email.Builder(title, to, content).bcc(bcc).build(); sendEmail(email); } //发送html模板邮件 private void sendEmail(Email email) { Long startTime = System.currentTimeMillis(); // 发件人 try { MimeMessage message = this.getMessage(email); // 新建一个存放信件内容的BodyPart对象 Multipart multiPart = new MimeMultipart(); MimeBodyPart mdp = new MimeBodyPart(); // 给BodyPart对象设置内容和格式/编码方式 setContent(email); mdp.setContent(email.getContent(), HTML_CONTENT); multiPart.addBodyPart(mdp); // 新建一个MimeMultipart对象用来存放BodyPart对象(事实上可以存放多个) if (null != email.getData()) { MimeBodyPart attchment = new MimeBodyPart(); ByteArrayInputStream in = new ByteArrayInputStream(email.getData()); DataSource fds = new ByteArrayDataSource(in, email.getFileType()); attchment.setDataHandler(new DataHandler(fds)); attchment.setFileName(MimeUtility.encodeText(email.getFileName())); multiPart.addBodyPart(attchment); if (in != null) { in.close(); } } message.setContent(multiPart); message.saveChanges(); Transport.send(message); Long endTime = System.currentTimeMillis(); log.info("邮件发送成功 耗时:" + (endTime - startTime) / 1000 + "s"); } catch (Exception e) { log.error("Error while sending mail.", e); } } private Email setContent(Email email) { if (StringUtils.isEmpty(email.getContent())) { email.setContent(""); } if (StringUtils.isNotEmpty(email.getTemplateName()) && null != email.getModel()) { String content = VelocityEngineUtils.mergeTemplateIntoString(velocityEngine, email.getTemplateName(), "UTF-8", email.getModel()); email.setContent(content); } return email; } public void setVelocityEngine(VelocityEngine velocityEngine) { this.velocityEngine = velocityEngine; } private MimeMessage getMessage(Email email) { Properties props = new Properties(); props.put("mail.smtp.host", "10.6.8.19"); props.put("mail.smtp.auth", "true"); props.put("username", "gyl_sys"); props.put("password", "wms,123456"); // 发件人 MimeMessage message = null; try { if (email.getTo() == null || email.getTo().length == 0 || StringUtils.isEmpty(email.getSubject())) { throw new Exception("接收人或主题为空"); } InternetAddress fromAddress = new InternetAddress("gyl_sys@111.com.cn"); // toemails(字符串，多个收件人用，隔开) Session mailSession = Session.getDefaultInstance(props, new Authenticator() { protected PasswordAuthentication getPasswordAuthentication() { return new PasswordAuthentication("gyl_sys", "wms,123456"); } }); message = new MimeMessage(mailSession); message.setFrom(fromAddress); for (String mailTo : email.getTo()) { message.addRecipient(Message.RecipientType.TO, new InternetAddress(mailTo)); } List ccAddress = new ArrayList<>(); if (null != email.getBcc()) { for (String mailCC : email.getBcc()) { ccAddress.add(new InternetAddress(mailCC)); } message.addRecipients(Message.RecipientType.CC, ccAddress.toArray(new InternetAddress[email.getBcc().length])); } message.setSentDate(new Date()); message.setSubject(email.getSubject()); } catch (Exception e) { log.error("Error while sending mail." + e.getMessage(), e); } return message; }}
绘制图表以及发送 SendDelayMailJobServiceImpl.java
package com.yyw.scs.service.impl;import com.yyw.scs.model.request.DelayResultDto;import com.yyw.scs.service.SendDelayMailJobService;import com.yyw.scs.util.DiamondScsConfig;import com.yyw.scs.util.MailUtils;import com.yyw.scs.wms.service.DelayRateService;import org.apache.commons.collections.CollectionUtils;import org.apache.log4j.Logger;import org.jfree.chart.ChartFactory;import org.jfree.chart.ChartUtilities;import org.jfree.chart.JFreeChart;import org.jfree.chart.axis.CategoryAxis;import org.jfree.chart.axis.ValueAxis;import org.jfree.chart.plot.CategoryPlot;import org.jfree.chart.plot.PlotOrientation;import org.jfree.chart.title.TextTitle;import org.jfree.data.category.CategoryDataset;import org.jfree.data.category.DefaultCategoryDataset;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import java.awt.*;import java.io.File;import java.io.FileOutputStream;import java.util.List;@Service("sendDelayMailJobService")public class SendDelayMailJobServiceImpl implements SendDelayMailJobService { @Autowired private MailUtils mailUtils; @Autowired private DelayRateService delayRateService; private final static Logger LOGGER = Logger.getLogger(SendDelayMailJobServiceImpl.class); @Override public Boolean send() { try { // 1. 得到数据 List res = delayRateService.findDelayResultDtoList(null, null, null, 1); if (!CollectionUtils.isNotEmpty(res)) { LOGGER.info("SendDelayMailJobServiceImpl.send nodata:"); return null; } CategoryDataset dataset = getDataSet(res); // 2. 构造chart JFreeChart chart = ChartFactory.createBarChart3D( "仓库履约实时分析", // 图表标题 "状态", // 目录轴的显示标签--横轴 "数量", // 数值轴的显示标签--纵轴 dataset, // 数据集 PlotOrientation.VERTICAL, // 图表方向：水平、 true, // 是否显示图例(对于简单的柱状图必须 false, // 是否生成工具 false // 是否生成URL链接 ); // 3. 处理chart中文显示问题 processChart(chart); // 4. chart输出图片 // 输出到本机TOMCAT路径// File directory = new File(".");// String path = null;// try {// path = directory.getCanonicalPath();// } catch (IOException e) {// // TODO Auto-generated catch block// e.printStackTrace();// }// path += "\\img\\delay.jpg"; // 输出到本机绝对路径 String path = "/app/img/"; File file = new File(path); System.out.println(path); if (!file.exists() && !file.isDirectory()) { file.mkdir(); } path += "delay.jpg"; writeChartAsImage(chart, path); // 5. chart 以swing形式输出// ChartFrame pieFrame = new ChartFrame("XXX", chart);// pieFrame.pack();// pieFrame.setVisible(true); // 6.发送邮件 List toList = DiamondScsConfig.getJobSendDelayToList(); if (CollectionUtils.isNotEmpty(toList)) { String[] toArr = (String[]) toList.toArray(new String[toList.size()]); mailUtils.sendEmail(res, path, "滞留率分析报表", toArr, null, "spring/email/delay-mail.vm"); } else { LOGGER.info("发送邮件： 未获取到收件人列表"); } } catch (Exception e) { LOGGER.error("SendDelayMailJobServiceImpl.send error:", e); // todo 发送报警邮件 return false; } return true; } /** * 获取一个演示用的组合数据集对象 * * @return */ private CategoryDataset getDataSet(List res) { DefaultCategoryDataset dataset = new DefaultCategoryDataset(); for (DelayResultDto item : res) { dataset.addValue(item.getCountInit(), item.getWarehouseName(), "初始化"); dataset.addValue(item.getCountPicking(), item.getWarehouseName(), "拣货中"); dataset.addValue(item.getCountPickFinish(), item.getWarehouseName(), "拣货完成"); dataset.addValue(item.getCountPacking(), item.getWarehouseName(), "装箱中"); dataset.addValue(item.getCountPackFinish(), item.getWarehouseName(), "装箱完成"); dataset.addValue(item.getCountTransferring(), item.getWarehouseName(), "交接中"); dataset.addValue(item.getCountTransferFinish(), item.getWarehouseName(), "交接完成"); dataset.addValue(item.getCountDelivery(), item.getWarehouseName(), "已出库"); } return dataset; } private CategoryDataset getDemoDataSet() { DefaultCategoryDataset dataset = new DefaultCategoryDataset(); dataset.addValue(100, "北京", "苹果"); dataset.addValue(120, "上海", "苹果"); dataset.addValue(160, "广州", "苹果"); dataset.addValue(210, "北京", "梨子"); dataset.addValue(220, "上海", "梨子"); dataset.addValue(230, "广州", "梨子"); dataset.addValue(330, "北京", "葡萄"); dataset.addValue(340, "上海", "葡萄"); dataset.addValue(340, "广州", "葡萄"); dataset.addValue(420, "北京", "香蕉"); dataset.addValue(430, "上海", "香蕉"); dataset.addValue(400, "广州", "香蕉"); dataset.addValue(510, "北京", "荔枝"); dataset.addValue(530, "上海", "荔枝"); dataset.addValue(510, "广州", "荔枝"); return dataset; } /** * 解决图表汉字显示问题 * * @param chart */ private static void processChart(JFreeChart chart) { CategoryPlot plot = chart.getCategoryPlot(); CategoryAxis domainAxis = plot.getDomainAxis(); ValueAxis rAxis = plot.getRangeAxis(); chart.getRenderingHints().put(RenderingHints.KEY_TEXT_ANTIALIASING, RenderingHints.VALUE_TEXT_ANTIALIAS_OFF); TextTitle textTitle = chart.getTitle(); textTitle.setFont(new Font("宋体", Font.PLAIN, 20)); domainAxis.setTickLabelFont(new Font("sans-serif", Font.PLAIN, 11)); domainAxis.setLabelFont(new Font("宋体", Font.PLAIN, 12)); rAxis.setTickLabelFont(new Font("sans-serif", Font.PLAIN, 12)); rAxis.setLabelFont(new Font("宋体", Font.PLAIN, 12)); chart.getLegend().setItemFont(new Font("宋体", Font.PLAIN, 12)); // renderer.setItemLabelGenerator(new LabelGenerator(0.0)); // renderer.setItemLabelFont(new Font("宋体", Font.PLAIN, 12)); // renderer.setItemLabelsVisible(true); } /** * 输出图片 * * @param chart */ private static void writeChartAsImage(JFreeChart chart, String path) { FileOutputStream fos_jpg = null; try { fos_jpg = new FileOutputStream(path); ChartUtilities.writeChartAsJPEG(fos_jpg, 1, chart, 800, 500, null); } catch (Exception e) { e.printStackTrace(); } finally { try { fos_jpg.close(); } catch (Exception e) { } } }} 补充：如果图片不能正常显示，需要将图片写入邮件附件，并用cid读取图片进行显示
ImageMailDto.java
package com.yyw.scs.model.request;import java.io.Serializable;/** * 邮件发送图片 */public class ImageMailDto implements Serializable { private static final long serialVersionUID = 1L; private byte[] imageData; private String imageCid; // "好好工作![](\"cid:abcd\")
" private String mimeType; // like image/jpeg、image/bmp、image/gif public byte[] getImageData() { return imageData; } public void setImageData(byte[] imageData) { this.imageData = imageData; } public String getImageCid() { return imageCid; } public void setImageCid(String imageCid) { this.imageCid = imageCid; } public String getMimeType() { return mimeType; } public void setMimeType(String mimeType) { this.mimeType = mimeType; }} MailUtil.java中
/** * 发送html模板邮件 */ private void sendEmail(Email email) { Long startTime = System.currentTimeMillis(); // 发件人 try { MimeMessage message = this.getMessage(email); // 新建一个存放信件内容的BodyPart对象 Multipart multiPart = new MimeMultipart(); MimeBodyPart mdp = new MimeBodyPart(); setContent(email); // 给BodyPart对象设置内容和格式/编码方式 mdp.setContent(email.getContent(), HTML_CONTENT); // 将BodyPart加入到MimeMultipart对象中(可以加入多个BodyPart) multiPart.addBodyPart(mdp); if (null != email.getData()) { MimeBodyPart attchment = new MimeBodyPart(); ByteArrayInputStream in = new ByteArrayInputStream(email.getData()); DataSource fds = new ByteArrayDataSource(in, email.getFileType()); attchment.setDataHandler(new DataHandler(fds)); attchment.setFileName(MimeUtility.encodeText(email.getFileName())); multiPart.addBodyPart(attchment); if (in != null) { in.close(); } } // 添加图片 if (email.getImageData() != null) { for (ImageMailDto dto : email.getImageData()) { MimeBodyPart image = new MimeBodyPart(); //javamail jaf image.setDataHandler(new DataHandler(new ByteArrayDataSource(dto.getImageData(), dto.getMimeType()))); image.setContentID(dto.getImageCid()); multiPart.addBodyPart(image); } } //把multiPart作为消息对象的内容 message.setContent(multiPart); message.saveChanges(); Transport.send(message); Long endTime = System.currentTimeMillis(); log.info("邮件发送成功 耗时:" + (endTime - startTime) / 1000 + "s"); } catch (Exception e) { log.error("Error while sending mail.", e); } } 最后发送邮件
byte[] data = null; try { FileOutputStream fos_jpg = new FileOutputStream(path); ParamChecks.nullNotPermitted(fos_jpg, "out"); ParamChecks.nullNotPermitted(chart, "chart"); BufferedImage image = chart.createBufferedImage(800, 500, 1, null); data = ChartUtilities.encodeAsPNG(image); } catch (Exception e) { e.printStackTrace(); } List toList = DiamondScsConfig.getJobSendDelayToList(); if (CollectionUtils.isNotEmpty(toList)) { String[] toArr = (String[]) toList.toArray(new String[toList.size()]); ImageMailDto[] imageMailDtos = new ImageMailDto[1]; ImageMailDto imageMailDto = new ImageMailDto(); imageMailDto.setImageCid("delay"); imageMailDto.setMimeType("image/png"); imageMailDto.setImageData(data); imageMailDtos[0] = imageMailDto; mailUtils.sendEmail(res, "滞留率分析报表", toArr, null, "spring/email/delay-mail.vm", imageMailDtos); } else { LOGGER.info("发送邮件： 未获取到收件人列表"); } 增加Email.java
package com.yyw.scs.model;import com.yyw.scs.model.request.ImageMailDto;import java.util.Map;public class Email { private String subject ; private String[] to; private String from = ""; private String content; // html邮件模板名称 private String templateName; private String[] bcc; private String logo; // html邮件data private Map model; // html邮件cid private String cid; private String fileName; // 附件邮件文件类型 private String fileType; // 附件byte流 private byte[] data; // 增加图片数据 private ImageMailDto[] imageData; public String getSubject() { return subject; } public void setSubject(String subject) { this.subject = subject; } public String[] getTo() { return to; } public void setTo(String[] to) { this.to = to; } public String getFrom() { return from; } public void setFrom(String from) { this.from = from; } public String getContent() { return content; } public void setContent(String content) { this.content = content; } public String getTemplateName() { return templateName; } public void setTemplateName(String templateName) { this.templateName = templateName; } public String[] getBcc() { return bcc; } public void setBcc(String[] bcc) { this.bcc = bcc; } public String getLogo() { return logo; } public void setLogo(String logo) { this.logo = logo; } public Map getModel() { return model; } public void setModel(Map model) { this.model = model; } public String getCid() { return cid; } public void setCid(String cid) { this.cid = cid; } public String getFileType() { return fileType; } public void setFileType(String fileType) { this.fileType = fileType; } public byte[] getData() { return data; } public void setData(byte[] data) { this.data = data; } public String getFileName() { return fileName; } public void setFileName(String fileName) { this.fileName = fileName; } public ImageMailDto[] getImageData() { return imageData; } public void setImageData(ImageMailDto[] imageData) { this.imageData = imageData; } public static class Builder{ private String subject ; private String[] to; private String from = ""; private String content; // html邮件模板名称 private String templateName; private String[] bcc; private String logo; // html邮件data private Map model; // html邮件cid private String cid; private String fileName; // 附件邮件文件类型 private String fileType; //附件byte流 private byte[] data; // 增加图片数据 private ImageMailDto[] imageData; public Builder(final String subject, final String[] to, final String content) { this.subject = subject; this.to = to; this.content = content; } public Builder(final String subject, final String[] to, final String content, final ImageMailDto[] imageData) { this.subject = subject; this.to = to; this.content = content; this.imageData = imageData; } public Builder subject(String subject) { this.subject = subject; return this; } public Builder to(String[] to) { this.to = to; return this; } public Builder from(String from) { this.from = from; return this; } public Builder content(String content) { this.content = content; return this; } public Builder templateName(String templateName) { this.templateName = templateName; return this; } public Builder bcc(String[] bcc) { this.bcc = bcc; return this; } public Builder logo(String logo) { this.logo = logo; return this; } public Builder model(Map model) { this.model = model; return this; } public Builder cid(String cid) { this.cid = cid; return this; } public Builder fileName(String fileName) { this.fileName = fileName; return this; } public Builder fileType(String fileType) { this.fileType = fileType; return this; } public Builder data(byte[] data) { this.data = data; return this; } public Builder imageData(ImageMailDto[] imageData) { this.imageData = imageData; return this; } public Email build(){ return new Email(this); } } private Email(Builder b) { this.subject = b.subject; this.to = b.to; this.from = b.from; this.content = b.content; this.templateName = b.templateName; this.bcc = b.bcc; this.logo = b.logo; this.model = b.model; this.cid = b.cid; this.fileName = b.fileName; this.fileType = b.fileType; this.data = b.data; this.imageData = b.imageData; }}